const mysql = require('mysql');
const { MYSQL_CONF } = require('../conf/db');

const con = mysql.createConnection(MYSQL_CONF);

con.connect();

function exec(sql) {
  const promise = new Promise((resolve, reject) => {
    // con.query是异步操作；
    /**
     * 这里没有con.end()，
     * 可以多次使用同一个con进行多次查询，相当于单例模式
     */
    con.query(sql, (err, res) => {
      if(err){
        reject(err);
      }
      resolve(res);
    })
  })
  return promise;
}

module.exports = {
  exec,
}
